8162ade3bf1f294a7999bdacf77745030627420d,graylog2-server/src/main/java/org/graylog2/shared/journal/KafkaJournal.java,KafkaJournal,KafkaJournal,#File#ScheduledExecutorService#Size#Duration#Size#Duration#number#Duration#MetricRegistry#,160
Before Change
// retentionSize: The approximate total number of bytes this log can use
retentionSize.toBytes(),
// retentionMs: The age approximate maximum age of the last segment that is retained
retentionAge.getMillis(),
// maxMessageSize: The maximum size of a message in the log
Integer.MAX_VALUE,
// maxIndexSize: The maximum size of an index file
After Change
// retentionSize: The approximate total number of bytes this log can use
.put(LogConfig.RetentionBytesProp(), retentionSize.toBytes())
// retentionMs: The age approximate maximum age of the last segment that is retained
.put(LogConfig.RetentionMsProp(), retentionAge.getMillis())
// maxMessageSize: The maximum size of a message in the log
.put(LogConfig.MaxMessageBytesProp(), Integer.MAX_VALUE)
// maxIndexSize: The maximum size of an index file
.put(LogConfig.SegmentIndexBytesProp(), Ints.saturatedCast(Size.megabytes(1L).toBytes()))
// indexInterval: The approximate number of bytes between index entries
.put(LogConfig.IndexIntervalBytesProp(), 4096)
// fileDeleteDelayMs: The time to wait before deleting a file from the filesystem
.put(LogConfig.FileDeleteDelayMsProp(), MINUTES.toMillis(1L))
// deleteRetentionMs: The time to retain delete markers in the log. Only applicable for logs that are being compacted.
.put(LogConfig.DeleteRetentionMsProp(), DAYS.toMillis(1L))
// minCleanableRatio: The ratio of bytes that are available for cleaning to the bytes already cleaned
.put(LogConfig.MinCleanableDirtyRatioProp(), 0.5)
// compact: Should old segments in this log be deleted or de-duplicated?
.put(LogConfig.Compact(), false)
// uncleanLeaderElectionEnable Indicates whether unclean leader election is enabled; actually a controller-level property
// but included here for topic-specific configuration validation purposes